package com.air.antispider.stream.rulecompute.businessprocess

import com.air.antispider.stream.commom.bean.{AntiCalculateResult, FlowCollocation, ProcessedData}
import org.apache.spark.rdd.RDD

import scala.collection.mutable.ArrayBuffer

object ComputeFlowScore {
  //获取黑名单计算结果
  def computeFlowScore(processedDataRDD: RDD[ProcessedData],
                       ipBlockMap: collection.Map[String, Int],
                       ipMap: collection.Map[String, Int],
                       ipCriticalPagesMap: collection.Map[String, Int],
                       ipUAMap: collection.Map[String, Int],
                       ipCriticalPagesMinTimeMap: collection.Map[String, Int],
                       ipCriticalPagesMinNumTimeMap: collection.Map[(String, String), Int],
                       ipArrCountMap: collection.Map[String, Int],
                       ipCookieCountMap: collection.Map[String, Int],
                       flowList: ArrayBuffer[FlowCollocation]): RDD[AntiCalculateResult] = {

    processedDataRDD.map(processedData => {


    })

  }

}
